package utils;

import com.hw.model.MetricDataBody;
import org.apache.flink.api.common.functions.ReduceFunction;

public class PerfReduceFunction implements ReduceFunction<MetricDataBody> {
    @Override
    public MetricDataBody reduce(MetricDataBody metricDataBody, MetricDataBody t1) throws Exception {
        return null;
    }
}
